package com.atguigu.gulimall.seckill.scheduled;

import com.atguigu.common.utils.AsyncUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.util.concurrent.CompletableFuture;

/**
 * 定时任务
 *      1)、@EnableScheduling 开启定时任务
 *      2）、 @Scheduled开启一个任务
 *      3）、自动配置类：TaskSchedulingAutoConfiguration
 * 异步任务：
 *      1）、@EnableAsync开启异步任务功能
 *      2）、@Async 给需要异步执行的方法  标注
 *      3）、自动配置类：TaskExecutionAutoConfiguration
 */
@EnableAsync
@Component
@EnableScheduling
@Slf4j
public class HelloScheduled {

    /**
     * 定时任务不应该阻塞，默认是阻塞的
     *     1）、可以让任务异步进行，自己提交到线程池
     *     2)、springboot 本身支持定时任务线程池,  spring.task.scheduling 绑定的配置  size  线程池的数量。实际情况并不好使，依然阻塞
     *     3）、
     */
//    @Scheduled(cron = "* * * ? * ?")
    public void hello() throws InterruptedException {
        //测试阻塞
//        log.info("hello...");
//        Thread.sleep(3000);

        //提交到线程池
//        CompletableFuture.runAsync(() -> {
//            log.info("hello...EXECUTOR");
//            try {
//                Thread.sleep(3000);
//            } catch (InterruptedException e) {
//                e.printStackTrace();
//            }
//        }, AsyncUtils.EXECUTOR);
    }

    /**
     * 启动异步的不需要设置线程池配置，默认是8个，最大 无限大
     * @throws InterruptedException
     */
//    @Async
//    @Scheduled(cron = "* * * ? * ?")
    public void asyncHello() throws InterruptedException {
        //测试阻塞
        log.info("hello...Async");
        Thread.sleep(3000);
    }
}
